package com.roy.KafkaTest.consumerGroup;

public class Note {
	
	/**
	 * 样例说明，针对kafka 0.10.1.1版本。
	 * testProducer发送kafka消息，并将消息均匀写入 四个 partition。
	 * 然后 四个 testConsumer指定了相同的group id。这样同一个consumer group下的这四个testConsumer会均匀的消费kafka上的消息。相当于rabbitmq的workder模式
	 * 另外，kafka可以配置多个consumer group,多个consumer group可以共同消费kafka上的消息。这又相当于是 发布订阅 模式
	 * 
	 */
}
